package com.bite.messageQueue.common;

import com.bite.messageQueue.mqServer.core.BasicProperties;

import java.io.IOException;

/**
 * 回调函数
 */
@FunctionalInterface
public interface Consumer {

    void handleDelivery(String consumertag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
